/**  
 * All rights Reserved, Designed By Suixingpay.
 * @author: chenfeifei[chen_ff@suixingpay.com] 
 * @date: 2017年9月21日 下午3:11:14   
 * @Copyright ©2017 Suixingpay. All rights reserved. 
 * 注意：本内容仅限于随行付支付有限公司内部传阅，禁止外泄以及用于其他的商业用途。
 */
package cn.hennancf.qieqie.mq.difficulty;

import java.io.IOException;

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;

/**  
 * MQ 基类
 * @author: chenfeifei[chen_ff@suixingpay.com]
 * @date: 2017年9月21日 下午3:11:14
 * @version: V1.0
 * @review: chenfeifei[chen_ff@suixingpay.com]/2017年9月21日 下午3:11:14
 */
public class BaseConnector {
    protected Channel channel;
    protected Connection connection;
    protected String queueName;

    public BaseConnector(String queueName) throws IOException {
        this.queueName = queueName;
        //打开连接和创建频道
        ConnectionFactory factory = new ConnectionFactory();
        //设置MabbitMQ所在主机ip或者主机名  127.0.0.1即localhost
        factory.setHost("127.0.0.1");
        //创建连接  
        connection = factory.newConnection();
        //创建频道  
        channel = connection.createChannel();
        //声明创建队列
        channel.queueDeclare(queueName, false, false, false, null);
    }
    

}
